package mylab.starters.eventbus.config.disruptor;

import lombok.Getter;
import mylab.starters.eventbus.config.EventBusCommonProperties;


@Getter
public class DisruptorProperties extends EventBusCommonProperties {

    /**
     * 缓冲区大小，默认1024*1024，必须是2的N次幂
     */
    private int ringBufferSize = 1024 * 1024;

    /**
     * 单生产者/多生产者
     */
    private boolean multiProducer = false;


    /**
     * 等待类型
     */
    private WaitType waitType = WaitType.BLOCKING_WAIT;
}